package com.watson.myflume;

import org.apache.flume.Event;
import org.apache.flume.interceptor.Interceptor;

import java.util.List;

/**
 * @program: mytest
 * @description: my process
 * @author: zhangpeng348@jd.com
 * @date: 2018-12-26 10:41
 **/
public class MyProcess implements Interceptor {
    @Override
    public void initialize() {

    }

    @Override
    public Event intercept(Event event) {
        return null;
    }

    @Override
    public List<Event> intercept(List<Event> list) {
        return null;
    }

    @Override
    public void close() {

    }
}
